package vip.xiaonuo.transaction;


import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.spring.annotation.MessageModel;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
import vip.xiaonuo.facedoor.modular.message.Topic;

@Component
@RocketMQMessageListener(
        topic = "vehicle_blacklist",                      // 1.topic：消息的发送者使用同一个topic
        consumerGroup = Topic.FACE_DOOR_MEMBER_USER_PUSH,               // 2.group：不用和生产者group相同 ( 在RocketMQ中消费者和发送者组没有关系 )
        selectorExpression = "${tag}",                   // 3.tag：设置为 * 时，表示全部。
        messageModel = MessageModel.CLUSTERING    // 4.消费模式：默认 CLUSTERING （ CLUSTERING：负载均衡 ）（ BROADCASTING：广播机制 ）
)
public class Listrener implements RocketMQListener<Message> {

    @Override
    public void onMessage(Message str) {
        System.out.println(str);
    }
}
